package org.breathe.dynamic.thread.pool.core.ai.assistant;

import reactor.core.publisher.Flux;

/**
 * @author: breathe
 * @createTime: 2025-06-27
 */
public interface Assistant {
    /**
     * 流式输出
     * @param userMessage 用户信息
     * @return 返回流式
     */
    Flux<String> chatByStreaming(String userMessage);

    /**
     * 阻塞输出
     * @param userMessage 用户信息
     * @return 返回所有的结果
     */
    String chatByBlocking(String userMessage);
}